1 启动消费者等待传入的订阅消息 2 发送延迟消息 3 确认 您应该会看到消息在其存 ...

上图是通过RocketMQ源码分析一个实现原理方案示意图。 分为两个部分： 消息的写入消息的Schedule 在写入CommitLog之前，如果是延迟消息，按照每10分钟写入delayfil ...